Code Coverage for /srv/pim/src/Akeneo/Pim/WorkOrganization/Workflow/Bundle/EventSubscriber/PublishedProduct/IndexProductsSubscriber.php

	Code Coverage
	Classes and Traits			Functions and Methods				Lines
Total	0.00% covered (danger)	0.00%	0 / 1	60.00% covered (warning)	60.00%	3 / 5	CRAP	90.32% covered (success)	90.32%	28 / 31
IndexProductsSubscriber	0.00% covered (danger)	0.00%	0 / 1	60.00% covered (warning)	60.00%	3 / 5	14.18	90.32% covered (success)	90.32%	28 / 31
__construct				100.00% covered (success)	100.00%	1 / 1	1	100.00% covered (success)	100.00%	3 / 3
getSubscribedEvents				0.00% covered (danger)	0.00%	0 / 1	1.30	33.33% covered (danger)	33.33%	1 / 3
indexProduct				100.00% covered (success)	100.00%	1 / 1	5	100.00% covered (success)	100.00%	9 / 9
bulkIndexProducts				0.00% covered (danger)	0.00%	0 / 1	4.02	88.89% covered (warning)	88.89%	8 / 9
deleteProduct				100.00% covered (success)	100.00%	1 / 1	3	100.00% covered (success)	100.00%	7 / 7

1	<?php
2
3	/*
4	* This file is part of the Akeneo PIM Enterprise Edition.
5	*
6	* (c) 2017 Akeneo SAS (http://www.akeneo.com)
7	*
8	* For the full copyright and license information, please view the LICENSE
9	* file that was distributed with this source code.
10	*/
11
12	namespace Akeneo\Pim\WorkOrganization\Workflow\Bundle\EventSubscriber\PublishedProduct;
13
14	use Akeneo\Pim\Enrichment\Bundle\Elasticsearch\Indexer\ProductIndexer;
15	use Akeneo\Pim\Enrichment\Component\Product\Model\ProductInterface;
16	use Akeneo\Pim\WorkOrganization\Workflow\Component\Model\PublishedProductInterface;
17	use Akeneo\Tool\Component\StorageUtils\Event\RemoveEvent;
18	use Akeneo\Tool\Component\StorageUtils\StorageEvents;
19	use Symfony\Component\EventDispatcher\EventSubscriberInterface;
20	use Symfony\Component\EventDispatcher\GenericEvent;
21
22	/**
23	* Index products and published products in the search engine.
24	*
25	* This is not done directly in the product saver as it's only a technical
26	* problem. The product saver only handles business stuff.
27	*
28	* This subscriber is also responsible for the indexing of published products. As the PublishedProduct class inherit
29	* from AbstractProduct, we need to route the saved entity to the correct indexer depending on its type.
30	*
31	* Note: We override the CE service `pim_catalog.event_subscriber.index_published_products` in order to avoid
32	* potential side effects as we define a clear and explicit routing logic in this class.
33	*
34	* @author Samir Boulil <samir.boulil@akeneo.com>
35	* @copyright 2017 Akeneo SAS (http://www.akeneo.com)
36	* @license http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0)
37	*/
38	class IndexProductsSubscriber implements EventSubscriberInterface
39	{
40	/** @var ProductIndexer */
41	protected $productIndexer;
42
43	/** @var ProductIndexer */
44	protected $publishedProductIndexer;
45
46	/**
47	* @param ProductIndexer $productIndexer
48	* @param ProductIndexer $publishedProductIndexer
49	*/
50	public function __construct(ProductIndexer $productIndexer, ProductIndexer $publishedProductIndexer)
51	{
52	$this->productIndexer = $productIndexer;
53	$this->publishedProductIndexer = $publishedProductIndexer;
54	}
55
56	/**
57	* {@inheritdoc}
58	*/
59	public static function getSubscribedEvents()
60	{
61	return [
62	StorageEvents::POST_SAVE => ['indexProduct', 300],
63	StorageEvents::POST_SAVE_ALL => ['bulkIndexProducts', 300],
64	StorageEvents::POST_REMOVE => ['deleteProduct', 300],
65	];
66	}
67
68	/**
69	* Index one single product or published product.
70	*
71	* @param GenericEvent $event
72	*/
73	public function indexProduct(GenericEvent $event)
74	{
75	$product = $event->getSubject();
76	if (!$product instanceof ProductInterface) {
77	return;
78	}
79
80	if (!$event->hasArgument('unitary') \|\| false === $event->getArgument('unitary')) {
81	return;
82	}
83
84	if ($product instanceof PublishedProductInterface) {
85	$this->publishedProductIndexer->index($product);
86	} else {
87	$this->productIndexer->index($product);
88	}
89	}
90
91	/**
92	* Index several products or published products at a time.
93	*
94	* @param GenericEvent $event
95	*/
96	public function bulkIndexProducts(GenericEvent $event)
97	{
98	$products = $event->getSubject();
99	if (!is_array($products)) {
100	return;
101	}
102
103	if (!current($products) instanceof ProductInterface) {
104	return;
105	}
106
107	if (current($products) instanceof PublishedProductInterface) {
108	$this->publishedProductIndexer->indexAll($products);
109	} else {
110	$this->productIndexer->indexAll($products);
111	}
112	}
113
114	/**
115	* Delete one single product or published product from the right ES index
116	*
117	* @param RemoveEvent $event
118	*/
119	public function deleteProduct(RemoveEvent $event)
120	{
121	$product = $event->getSubject();
122	if (!$product instanceof ProductInterface) {
123	return;
124	}
125
126	if ($product instanceof PublishedProductInterface) {
127	$this->publishedProductIndexer->remove($event->getSubjectId());
128	} else {
129	$this->productIndexer->remove($event->getSubjectId());
130	}
131	}
132	}